/*
 * @Description: 
 * @Author: changqing
 * @Date: 2021-08-30 19:40:25
 * @LastEditTime: 2021-08-30 19:41:46
 * @LastEditors: changqing
 * @Usage: 
 */
//从执行结果可以看出，source1因为没有主动去执行connect的关系，虽然有订阅，但没有开始；source2则使用refCount帮我们执行connect，因些当订阅发生时，整个数据流就会直接开始
var { timer, interval,range,from,Subject } = require('rxjs'); 
var {take,map, multicast,publish,refCount} = require('rxjs/operators');

const source1 = interval(1000).pipe(
  take(5),
  publish()
);

const source2 = interval(1000).pipe(
  take(5),
  publish(),
  refCount(),
);

source1.subscribe((data) => {
  console.log(`source1>>>${data}`);
});

source2.subscribe((data) => {
  console.log(`source2>>>${data}`);
});
// source2>>>0
// source2>>>1
// source2>>>2
// source2>>>3
// source2>>>4